8a7f299aa946e92e8a0e0cb897d36491218a28ee,sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunnerTest.java,DataflowPipelineRunnerTest,testInvalidNumberOfWorkerHarnessThreads,#,644

Before Change


    options.setProject("foo-12345");

    options.setStagingLocation("gs://spam/ham/eggs");
    options.setGcsUtil(buildMockGcsUtil(true /* bucket exists */));

    options.as(DataflowPipelineDebugOptions.class).setNumberOfWorkerHarnessThreads(-1);

After Change


    DataflowPipelineOptions options = PipelineOptionsFactory.as(DataflowPipelineOptions.class);
    options.setRunner(DataflowPipelineRunner.class);
    options.setProject("foo-12345");
    options.setGcsUtil(mockGcsUtil);

    options.setStagingLocation(VALID_GS_SPAM_HAM_EGGS);
    options.as(DataflowPipelineDebugOptions.class).setNumberOfWorkerHarnessThreads(-1);